package com.codeduck.demo.withjava;

import com.codeduck.constant.KafkaConst;
import lombok.extern.slf4j.Slf4j;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

/**
 * @author: <a href="mailto:codeduck@163.com">codeduck</a>
 * @date: 2023/01/14
 */
@Service
@Slf4j
public class MsgConsumer {

//    @KafkaListener(id = "java_consumer_01", topics = KafkaConst.JAVA_TOPIC_01)
    public void listen(String msg) {
        log.info("SimpleConsumer: 获得消息 [{}]", msg);
    }
}
